package com.gitee.xhs.keyedState.mapState;

import org.apache.flink.api.common.state.MapStateDescriptor;
import org.apache.flink.api.common.typeinfo.TypeInformation;

import static com.gitee.xhs.StateConstant.FLINK_CHECK_POINT_PATH;

/**
 * @author BigHead
 * @date 2022/6/30 16:22
 * @description MapStateConstant
 */
public class MapStateConstant {

    public static final String CUSTOM_MAP_STATE_DIR = "mapState/";

    public static final String MAP_STATE_PATH = FLINK_CHECK_POINT_PATH + CUSTOM_MAP_STATE_DIR;
    public static final String MAP_STATE_UID = "map-state-uid";
    public static final String MAP_STATE_NAME = "map-state";
    public static final MapStateDescriptor<Integer, Double> MAP_STATE_DESCRIPTOR = new MapStateDescriptor<Integer, Double>(
            MAP_STATE_NAME,
            TypeInformation.of(Integer.class),
            TypeInformation.of(Double.class)
    );


}
